package com.gitee.xhs.customWaterMark;

import com.gitee.xhs.sampleRecod.transactionRecord.Transaction;
import org.apache.flink.api.common.eventtime.SerializableTimestampAssigner;

/**
 * @author BigHead
 * @date 2022/7/15 16:23
 * @description CustomSerializableTimestampAssigner
 */
public class CustomSerializableTimestampAssigner implements SerializableTimestampAssigner<Transaction> {

    @Override
    public long extractTimestamp(Transaction element, long recordTimestamp) {
        return element.getTimestamp();
    }

}